package cron

import (
	"log"
	"path/filepath"
	"time"

	"github.com/gin-gonic/gin"
	"github.com/robfig/cron"
	"github.com/spf13/cobra"
	"github.com/spf13/viper"
	"go-papers/cache"
	"go-papers/crontab/cronorder"
	"go-papers/crontab/cronsys"
	"go-papers/pkg/aliyun"

	"go-papers/database"
	"go-papers/models/mysql"
	"go-papers/pkg/lognew"
	"go-papers/pkg/redis"
	"go-papers/pkg/sql"
	"go-papers/pkg/wechat"
	"go-papers/tools"
	config2 "go-papers/tools/config"
)

var (
	config  string
	port    string
	mode    string
	CronCmd = &cobra.Command{
		Use:     "crontab",
		Short:   "Start crontab server",
		Example: "go-papers crontab config/settings.yml",
		PreRun: func(cmd *cobra.Command, args []string) {
			usage()
			setup()
		},
		RunE: func(cmd *cobra.Command, args []string) error {
			return run()
		},
	}
)

func init() {
	CronCmd.PersistentFlags().StringVarP(&config, "config", "c", "config/", "Start server with provided configuration file")
	CronCmd.PersistentFlags().StringVarP(&port, "port", "p", "8000", "Tcp port server listening on")
	CronCmd.PersistentFlags().StringVarP(&mode, "mode", "m", "local", "server mode ; eg:dev,test,prod")
}

func usage() {
	// usageStr := `starting api server`
	// fmt.Printf("%s\n", usageStr)
}

func setup() {

	// 如果config使用的是绝对路径，则config为路径，mode为文件名
	if filepath.IsAbs(config) {
		config, mode = filepath.Split(config)
		log.Println("config:", config, "  mode:", mode)
	} else {
		if mode == "prod" {
			config = "config/"
		}
		log.Println("Default LIST config:", config, "  mode:", mode)
	}

	// 1. 读取配置 初始化公共配置
	config2.InitGconfig(mode, config)

	// 2. 设置日志
	tools.InitLogger()
	lognew.Init()
	// 初始化公共组件
	// 初始化 redis 组件
	redis.Init()
	// 初始化 httpclient 组件

	// 初始化 mysql 组件
	sql.Init()

	// 3. 初始化数据库链接
	cache.Init()

	wechat.Init()
	aliyun.Init()

	// 初始化 oss 组件
	// oss.Init()

	mysql.Init()

	database.Setup()

	//4. 设置gin mode
	if viper.GetString("settings.application.mode") == string(tools.ModeProd) {
		gin.SetMode(gin.ReleaseMode)
	} else {
		gin.SetMode(gin.TestMode)
	}
}

func run() error {

	defer database.Eloquent.Close()

	log.Println("Starting...")

	// 秒(0-59) 分(0-59) 时(0-23) 一个月中的某天(1-31) 月(1-12) 星期几(0-6 )
	//每隔1分钟执行一次：0 */1 * * * ?
	//
	//        每天23点执行一次：0 0 23 * * ?
	//
	//        每天凌晨1点执行一次：0 0 1 * * ?
	//
	//        每月1号凌晨1点执行一次：0 0 1 1 * ?
	//
	//        在26分、29分、33分执行一次：0 26,29,33 * * * ?
	//
	//        每天的0点、13点、18点、21点都执行一次：0 0 0,13,18,21 * * ?

	c := cron.New()

	_ = c.AddFunc("0 */10 * * * *", func() {
		cronorder.CleanOrder()
	})

	_ = c.AddFunc("0 */15 * * * *", func() {
		cronorder.SureOrder()
	})

	_ = c.AddFunc("0 */30 * * * *", func() {
		cronsys.CleanLog()
	})

	c.Start()

	t1 := time.NewTimer(time.Second * 10)
	for {
		select {
		case <-t1.C:
			t1.Reset(time.Second * 10)
		}
	}
}
